#if !defined(__APP_MQTT_H__)
#define __APP_MQTT_H__

#define ADDRESS     "ws://192.168.23.125:1883"
#define CLIENTID    "90ec8ca7-124f-4ece-8288-4c4a12cf1941" 
#define TOPIC_RTG       "remote_to_gateway"   //订阅主题
#define TOPIC_GTR       "gateway_to_remote"   //发布主题
#define QOS         1
#define TIMEOUT     10000L

//初始化MQTT客户端
int app_mqtt_init(void);

//关闭MQTT客户端
void app_mqtt_close(void);

//发布消息到MQTT服务器
int app_mqtt_send(char *json);

//注册接收消息回调函数（当收到消息时调用）
//回调函数接收的也是json格式字符串,返回int表示接受成功与否
void app_mqtt_registRecvCallback(int (*callback)(char *json));

#endif // __APP_MQTT_H__
